package com.cheerscpl.service;

import com.cheerscpl.TaskQueue;

import java.util.Set;

/**
 * Created by chenpuliang on 2017/6/4.
 */
public interface TaskQueueService {


    void initQueue();

    /**
     * 同步redis数据,维护当前机器连接设备
     * 队列到本地内存
     */
    void refreshQueue();

    /**
     * 增加队列
     * @param taskQueue
     */
    void addQueue(TaskQueue taskQueue);

    /**
     * 获取队列
     * @param name
     * @return
     */
    TaskQueue getTaskQueue(String name);

    /**
     * 获取TaskQueue
     * @return
     */
    Set<TaskQueue> getQueueSet();

}
